package consumer

type HandleFunc func(topic string, msg string, partition int32, offset int64)

type EKafkaConsumerConfig struct {
	Brokers        []string `ini:"brokers"`    //kafka broker地址列表
	Zookeepers     []string `ini:"zookeepers"` //zookeeper地址列表
	Version        string   `ini:"version"`
	Topics         []string `ini:"topics"`
	Group          string   `ini:"group"`
	Workers        int      `ini:"workers"`
	MannulCommit   bool     `ini:mannulcommit`
	CommitInterval int      `ini:commitinterval`
	Verbose        bool     `ini:"verbose"`
}
